//package com.moli.iov.task.jobhandler;
//
//import com.moli.iov.producer.KafkaProducerServer;
//import com.xxl.job.core.biz.model.ReturnT;
//import com.xxl.job.core.handler.IJobHandler;
//import com.xxl.job.core.handler.annotation.JobHander;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.stereotype.Component;
//
//import java.util.Map;
//
///**
// * <p>
// *  同步车辆在线状态
// * </p>
// *
// * @author: zql
// * @Date: 2019/4/11 17:41
// */
//@Slf4j
//@JobHander(value="iovVehicleSyncJobHandler")
//@Component
//public class IovVehicleSyncJobHandler extends IJobHandler {
//
//    @Autowired
//    private KafkaProducerServer kafkaProducerServer;
//
//    @Value("${kafka.sync.topic}")
//    private String topic;
//
//    @Override
//    public ReturnT<String> execute(String... params){
//        try {
//            send();
//            return ReturnT.SUCCESS;
//        }catch(Exception e){
//            log.error("同步车辆在线状态 异常", e);
//            return ReturnT.FAIL;
//        }
//    }
//
//    /**
//     * 发送消息 通知网关
//     */
//    public void send(){
//
//        String key = "VehicleSync";
//        String val = "同步车辆在线状态";
//        log.info("[同步车辆在线状态] Kafka推送数据 topic:{} key:{} val:{}", topic, key, val);
//
//        Map<String, Object> res = kafkaProducerServer.sndMesForTemplate(topic, key, val);
//
//        log.info("[同步车辆在线状态] Kafka 推送数据 topic:{} 结果返回：{}", topic, res);
//    }
//
//
//}
